package com.qingyan.flink.core;

import lombok.Getter;
import lombok.Setter;
import lombok.extern.slf4j.Slf4j;

import java.io.Serializable;
import java.util.List;
import java.util.Map;

/**
 * @author yangzhi
 * @date 2021/11/11
 * @email csfrez@163.com
 */
@Slf4j
@Getter
@Setter
public class SourceConfig implements Serializable {

    private static final long serialVersionUID = 1L;

    private Map<String, Object> configMap;
    // 映射
    private Map<String, String> tableNameMap;

    private List<TableInfo> tableInfoList;

    private String host;

    private int port;

    private String db;

    private String username;

    private String password;

    private String tableNames;

}
